let server = require('express')();
let mysql = require('mysql');
const port = 82;

// 解决跨域
server.all("*", function(req, res, next) {
	//设置允许跨域的域名，*代表允许任意域名跨域
	res.header("Access-Control-Allow-Origin", "*");
	//允许的header类型
	res.header("Access-Control-Allow-Headers", "content-type");
	//跨域允许的请求方式 
	res.header("Access-Control-Allow-Methods", "DELETE,PUT,POST,GET,OPTIONS");
	if (req.method.toLowerCase() == 'options')
		res.send(200); //让options尝试请求快速结束
	else
		next();
})

//规划链接
let sql = mysql.createConnection({
	host: 'localhost',
	user: 'root',
	password: '123456',
	database: 'website'
})

//尝试链接
sql.connect();
// 数据
server.get("/message", function(request, response) {
	sql.query('SELECT * FROM message ORDER BY id', function(error, data) {
		if (error) {
			console.log(error);
			response.end("error");
			return;
		}
		response.end(JSON.stringify(data));
	})
})
server.get("/article", function(request, response) {
	let id = request.query.id;
	sql.query(`SELECT article,title,labels,date,cases FROM message WHERE id=${id}`, function(error, data) {
		if (error) {
			console.log(error);
			response.end("error");
			return;
		}
		response.end(JSON.stringify(data));
	})
})
server.listen(port);
console.log(`server is running at ${port}`);
